ortools.sat.cp_model_pb2

488  def init(self, **kwargs):
489    self._cached_byte_size = 0
490    self._cached_byte_size_dirty = len(kwargs) > 0
491    self._fields = {}
492    # Contains a mapping from oneof field descriptors to the descriptor
493    # of the currently set field in that oneof field.
494    self._oneofs = {}
495
496    # _unknown_fields is () when empty for efficiency, and will be turned into
497    # a list if fields are added.
498    self._unknown_fields = ()
499    # _unknown_field_set is None when empty for efficiency, and will be
500    # turned into UnknownFieldSet struct if fields are added.
501    self._unknown_field_set = None      # pylint: disable=protected-access
502    self._is_present_in_parent = False
503    self._listener = message_listener_mod.NullMessageListener()
504    self._listener_for_children = _Listener(self)
505    for field_name, field_value in kwargs.items():
506      field = _GetFieldByName(message_descriptor, field_name)
507      if field is None:
508        raise TypeError('%s() got an unexpected keyword argument "%s"' %
509                        (message_descriptor.name, field_name))
510      if field_value is None:
511        # field=None is the same as no field at all.
512        continue
513      if field.label == _FieldDescriptor.LABEL_REPEATED:
514        copy = field._default_constructor(self)
515        if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:  # Composite
516          if _IsMapField(field):
517            if _IsMessageMapField(field):
518              for key in field_value:
519                copy[key].MergeFrom(field_value[key])
520            else:
521              copy.update(field_value)
522          else:
523            for val in field_value:
524              if isinstance(val, dict):
525                copy.add(**val)
526              else:
527                copy.add().MergeFrom(val)
528        else:  # Scalar
529          if field.cpp_type == _FieldDescriptor.CPPTYPE_ENUM:
530            field_value = [_GetIntegerEnumValue(field.enum_type, val)
531                           for val in field_value]
532          copy.extend(field_value)
533        self._fields[field] = copy
534      elif field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
535        copy = field._default_constructor(self)
536        new_val = field_value
537        if isinstance(field_value, dict):
538          new_val = field.message_type._concrete_class(**field_value)
539        try:
540          copy.MergeFrom(new_val)
541        except TypeError:
542          _ReraiseTypeErrorWithFieldName(message_descriptor.name, field_name)
543        self._fields[field] = copy
544      else:
545        if field.cpp_type == _FieldDescriptor.CPPTYPE_ENUM:
546          field_value = _GetIntegerEnumValue(field.enum_type, field_value)
547        try:
548          setattr(self, field_name, field_value)
549        except TypeError:
550          _ReraiseTypeErrorWithFieldName(message_descriptor.name, field_name)

1288  def MergeFrom(self, msg):
1289    if not isinstance(msg, cls):
1290      raise TypeError(
1291          'Parameter to MergeFrom() must be instance of same class: '
1292          'expected %s got %s.' % (_FullyQualifiedClassName(cls),
1293                                   _FullyQualifiedClassName(msg.__class__)))
1294
1295    assert msg is not self
1296    self._Modified()
1297
1298    fields = self._fields
1299
1300    for field, value in msg._fields.items():
1301      if field.label == LABEL_REPEATED:
1302        field_value = fields.get(field)
1303        if field_value is None:
1304          # Construct a new object to represent this field.
1305          field_value = field._default_constructor(self)
1306          fields[field] = field_value
1307        field_value.MergeFrom(value)
1308      elif field.cpp_type == CPPTYPE_MESSAGE:
1309        if value._is_present_in_parent:
1310          field_value = fields.get(field)
1311          if field_value is None:
1312            # Construct a new object to represent this field.
1313            field_value = field._default_constructor(self)
1314            fields[field] = field_value
1315          field_value.MergeFrom(value)
1316      else:
1317        self._fields[field] = value
1318        if field.containing_oneof:
1319          self._UpdateOneofState(field)
1320
1321    if msg._unknown_fields:
1322      if not self._unknown_fields:
1323        self._unknown_fields = []
1324      self._unknown_fields.extend(msg._unknown_fields)
1325      # pylint: disable=protected-access
1326      if self._unknown_field_set is None:
1327        self._unknown_field_set = containers.UnknownFieldSet()
1328      self._unknown_field_set._extend(msg._unknown_field_set)

1351def _Clear(self):
1352  # Clear fields.
1353  self._fields = {}
1354  self._unknown_fields = ()
1355  # pylint: disable=protected-access
1356  if self._unknown_field_set is not None:
1357    self._unknown_field_set._clear()
1358    self._unknown_field_set = None
1359
1360  self._oneofs = {}
1361  self._Modified()

1423  def Modified(self):
1424    """Sets the _cached_byte_size_dirty bit to true,
1425    and propagates this to our listener iff this was a state change.
1426    """
1427
1428    # Note:  Some callers check _cached_byte_size_dirty before calling
1429    #   _Modified() as an extra optimization.  So, if this method is ever
1430    #   changed such that it does stuff even when _cached_byte_size_dirty is
1431    #   already true, the callers need to be updated.
1432    if not self._cached_byte_size_dirty:
1433      self._cached_byte_size_dirty = True
1434      self._listener_for_children.dirty = True
1435      self._is_present_in_parent = True
1436      self._listener.Modified()

1188  def IsInitialized(self, errors=None):
1189    """Checks if all required fields of a message are set.
1190
1191    Args:
1192      errors:  A list which, if provided, will be populated with the field
1193               paths of all missing required fields.
1194
1195    Returns:
1196      True iff the specified message has all required fields set.
1197    """
1198
1199    # Performance is critical so we avoid HasField() and ListFields().
1200
1201    for field in required_fields:
1202      if (field not in self._fields or
1203          (field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE and
1204           not self._fields[field]._is_present_in_parent)):
1205        if errors is not None:
1206          errors.extend(self.FindInitializationErrors())
1207        return False
1208
1209    for field, value in list(self._fields.items()):  # dict can change size!
1210      if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
1211        if field.label == _FieldDescriptor.LABEL_REPEATED:
1212          if (field.message_type.has_options and
1213              field.message_type.GetOptions().map_entry):
1214            continue
1215          for element in value:
1216            if not element.IsInitialized():
1217              if errors is not None:
1218                errors.extend(self.FindInitializationErrors())
1219              return False
1220        elif value._is_present_in_parent and not value.IsInitialized():
1221          if errors is not None:
1222            errors.extend(self.FindInitializationErrors())
1223          return False
1224
1225    return True

1103  def MergeFromString(self, serialized):
1104    serialized = memoryview(serialized)
1105    length = len(serialized)
1106    try:
1107      if self._InternalParse(serialized, 0, length) != length:
1108        # The only reason _InternalParse would return early is if it
1109        # encountered an end-group tag.
1110        raise message_mod.DecodeError('Unexpected end-group tag.')
1111    except (IndexError, TypeError):
1112      # Now ord(buf[p:p+1]) == ord('') gets TypeError.
1113      raise message_mod.DecodeError('Truncated message.')
1114    except struct.error as e:
1115      raise message_mod.DecodeError(e)
1116    return length   # Return this for legacy reasons.

1059  def SerializeToString(self, **kwargs):
1060    # Check if the message has all of its required fields set.
1061    if not self.IsInitialized():
1062      raise message_mod.EncodeError(
1063          'Message %s is missing required fields: %s' % (
1064          self.DESCRIPTOR.full_name, ','.join(self.FindInitializationErrors())))
1065    return self.SerializePartialToString(**kwargs)

1072  def SerializePartialToString(self, **kwargs):
1073    out = BytesIO()
1074    self._InternalSerialize(out.write, **kwargs)
1075    return out.getvalue()

806  def ListFields(self):
807    all_fields = [item for item in self._fields.items() if _IsPresent(item)]
808    all_fields.sort(key = lambda item: item[0].number)
809    return all_fields

830  def HasField(self, field_name):
831    try:
832      field = hassable_fields[field_name]
833    except KeyError as exc:
834      raise ValueError('Protocol message %s has no non-repeated field "%s" '
835                       'nor has presence is not available for this field.' % (
836                           message_descriptor.full_name, field_name)) from exc
837
838    if isinstance(field, descriptor_mod.OneofDescriptor):
839      try:
840        return HasField(self, self._oneofs[field].name)
841      except KeyError:
842        return False
843    else:
844      if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
845        value = self._fields.get(field)
846        return value is not None and value._is_present_in_parent
847      else:
848        return field in self._fields

855  def ClearField(self, field_name):
856    try:
857      field = message_descriptor.fields_by_name[field_name]
858    except KeyError:
859      try:
860        field = message_descriptor.oneofs_by_name[field_name]
861        if field in self._oneofs:
862          field = self._oneofs[field]
863        else:
864          return
865      except KeyError:
866        raise ValueError('Protocol message %s has no "%s" field.' %
867                         (message_descriptor.name, field_name))
868
869    if field in self._fields:
870      # To match the C++ implementation, we need to invalidate iterators
871      # for map fields when ClearField() happens.
872      if hasattr(self._fields[field], 'InvalidateIterators'):
873        self._fields[field].InvalidateIterators()
874
875      # Note:  If the field is a sub-message, its listener will still point
876      #   at us.  That's fine, because the worst than can happen is that it
877      #   will call _Modified() and invalidate our byte size.  Big deal.
878      del self._fields[field]
879
880      if self._oneofs.get(field.containing_oneof, None) is field:
881        del self._oneofs[field.containing_oneof]
882
883    # Always call _Modified() -- even if nothing was changed, this is
884    # a mutating method, and thus calling it should cause the field to become
885    # present in the parent message.
886    self._Modified()

1334  def WhichOneof(self, oneof_name):
1335    """Returns the name of the currently set field inside a oneof, or None."""
1336    try:
1337      field = message_descriptor.oneofs_by_name[oneof_name]
1338    except KeyError:
1339      raise ValueError(
1340          'Protocol message has no oneof "%s" field.' % oneof_name)
1341
1342    nested_field = self._oneofs.get(field, None)
1343    if nested_field is not None and self.HasField(nested_field.name):
1344      return nested_field.name
1345    else:
1346      return None

1364def _UnknownFields(self):
1365  if self._unknown_field_set is None:  # pylint: disable=protected-access
1366    # pylint: disable=protected-access
1367    self._unknown_field_set = containers.UnknownFieldSet()
1368  return self._unknown_field_set    # pylint: disable=protected-access

1371def _DiscardUnknownFields(self):
1372  self._unknown_fields = []
1373  self._unknown_field_set = None      # pylint: disable=protected-access
1374  for field, value in self.ListFields():
1375    if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
1376      if _IsMapField(field):
1377        if _IsMessageMapField(field):
1378          for key in value:
1379            value[key].DiscardUnknownFields()
1380      elif field.label == _FieldDescriptor.LABEL_REPEATED:
1381        for sub_message in value:
1382          sub_message.DiscardUnknownFields()
1383      else:
1384        value.DiscardUnknownFields()

1032  def ByteSize(self):
1033    if not self._cached_byte_size_dirty:
1034      return self._cached_byte_size
1035
1036    size = 0
1037    descriptor = self.DESCRIPTOR
1038    if descriptor.GetOptions().map_entry:
1039      # Fields of map entry should always be serialized.
1040      size = descriptor.fields_by_name['key']._sizer(self.key)
1041      size += descriptor.fields_by_name['value']._sizer(self.value)
1042    else:
1043      for field_descriptor, field_value in self.ListFields():
1044        size += field_descriptor._sizer(field_value)
1045      for tag_bytes, value_bytes in self._unknown_fields:
1046        size += len(tag_bytes) + len(value_bytes)
1047
1048    self._cached_byte_size = size
1049    self._cached_byte_size_dirty = False
1050    self._listener_for_children.dirty = False
1051    return size

784  def FromString(s):
785    message = cls()
786    message.MergeFromString(s)
787    return message

776  def RegisterExtension(field_descriptor):
777    field_descriptor.containing_type = cls.DESCRIPTOR
778    # TODO(amauryfa): Use cls.MESSAGE_FACTORY.pool when available.
779    # pylint: disable=protected-access
780    cls.DESCRIPTOR.file.pool._AddExtensionDescriptor(field_descriptor)
781    _AttachFieldHelpers(cls, field_descriptor)

1229  def FindInitializationErrors(self):
1230    """Finds required fields which are not initialized.
1231
1232    Returns:
1233      A list of strings.  Each string is a path to an uninitialized field from
1234      the top-level message, e.g. "foo.bar[5].baz".
1235    """
1236
1237    errors = []  # simplify things
1238
1239    for field in required_fields:
1240      if not self.HasField(field.name):
1241        errors.append(field.name)
1242
1243    for field, value in self.ListFields():
1244      if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
1245        if field.is_extension:
1246          name = '(%s)' % field.full_name
1247        else:
1248          name = field.name
1249
1250        if _IsMapField(field):
1251          if _IsMessageMapField(field):
1252            for key in value:
1253              element = value[key]
1254              prefix = '%s[%s].' % (name, key)
1255              sub_errors = element.FindInitializationErrors()
1256              errors += [prefix + error for error in sub_errors]
1257          else:
1258            # ScalarMaps can't have any initialization errors.
1259            pass
1260        elif field.label == _FieldDescriptor.LABEL_REPEATED:
1261          for i in range(len(value)):
1262            element = value[i]
1263            prefix = '%s[%d].' % (name, i)
1264            sub_errors = element.FindInitializationErrors()
1265            errors += [prefix + error for error in sub_errors]
1266        else:
1267          prefix = name + '.'
1268          sub_errors = value.FindInitializationErrors()
1269          errors += [prefix + error for error in sub_errors]
1270
1271    return errors

488  def init(self, **kwargs):
489    self._cached_byte_size = 0
490    self._cached_byte_size_dirty = len(kwargs) > 0
491    self._fields = {}
492    # Contains a mapping from oneof field descriptors to the descriptor
493    # of the currently set field in that oneof field.
494    self._oneofs = {}
495
496    # _unknown_fields is () when empty for efficiency, and will be turned into
497    # a list if fields are added.
498    self._unknown_fields = ()
499    # _unknown_field_set is None when empty for efficiency, and will be
500    # turned into UnknownFieldSet struct if fields are added.
501    self._unknown_field_set = None      # pylint: disable=protected-access
502    self._is_present_in_parent = False
503    self._listener = message_listener_mod.NullMessageListener()
504    self._listener_for_children = _Listener(self)
505    for field_name, field_value in kwargs.items():
506      field = _GetFieldByName(message_descriptor, field_name)
507      if field is None:
508        raise TypeError('%s() got an unexpected keyword argument "%s"' %
509                        (message_descriptor.name, field_name))
510      if field_value is None:
511        # field=None is the same as no field at all.
512        continue
513      if field.label == _FieldDescriptor.LABEL_REPEATED:
514        copy = field._default_constructor(self)
515        if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:  # Composite
516          if _IsMapField(field):
517            if _IsMessageMapField(field):
518              for key in field_value:
519                copy[key].MergeFrom(field_value[key])
520            else:
521              copy.update(field_value)
522          else:
523            for val in field_value:
524              if isinstance(val, dict):
525                copy.add(**val)
526              else:
527                copy.add().MergeFrom(val)
528        else:  # Scalar
529          if field.cpp_type == _FieldDescriptor.CPPTYPE_ENUM:
530            field_value = [_GetIntegerEnumValue(field.enum_type, val)
531                           for val in field_value]
532          copy.extend(field_value)
533        self._fields[field] = copy
534      elif field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
535        copy = field._default_constructor(self)
536        new_val = field_value
537        if isinstance(field_value, dict):
538          new_val = field.message_type._concrete_class(**field_value)
539        try:
540          copy.MergeFrom(new_val)
541        except TypeError:
542          _ReraiseTypeErrorWithFieldName(message_descriptor.name, field_name)
543        self._fields[field] = copy
544      else:
545        if field.cpp_type == _FieldDescriptor.CPPTYPE_ENUM:
546          field_value = _GetIntegerEnumValue(field.enum_type, field_value)
547        try:
548          setattr(self, field_name, field_value)
549        except TypeError:
550          _ReraiseTypeErrorWithFieldName(message_descriptor.name, field_name)

1288  def MergeFrom(self, msg):
1289    if not isinstance(msg, cls):
1290      raise TypeError(
1291          'Parameter to MergeFrom() must be instance of same class: '
1292          'expected %s got %s.' % (_FullyQualifiedClassName(cls),
1293                                   _FullyQualifiedClassName(msg.__class__)))
1294
1295    assert msg is not self
1296    self._Modified()
1297
1298    fields = self._fields
1299
1300    for field, value in msg._fields.items():
1301      if field.label == LABEL_REPEATED:
1302        field_value = fields.get(field)
1303        if field_value is None:
1304          # Construct a new object to represent this field.
1305          field_value = field._default_constructor(self)
1306          fields[field] = field_value
1307        field_value.MergeFrom(value)
1308      elif field.cpp_type == CPPTYPE_MESSAGE:
1309        if value._is_present_in_parent:
1310          field_value = fields.get(field)
1311          if field_value is None:
1312            # Construct a new object to represent this field.
1313            field_value = field._default_constructor(self)
1314            fields[field] = field_value
1315          field_value.MergeFrom(value)
1316      else:
1317        self._fields[field] = value
1318        if field.containing_oneof:
1319          self._UpdateOneofState(field)
1320
1321    if msg._unknown_fields:
1322      if not self._unknown_fields:
1323        self._unknown_fields = []
1324      self._unknown_fields.extend(msg._unknown_fields)
1325      # pylint: disable=protected-access
1326      if self._unknown_field_set is None:
1327        self._unknown_field_set = containers.UnknownFieldSet()
1328      self._unknown_field_set._extend(msg._unknown_field_set)

1351def _Clear(self):
1352  # Clear fields.
1353  self._fields = {}
1354  self._unknown_fields = ()
1355  # pylint: disable=protected-access
1356  if self._unknown_field_set is not None:
1357    self._unknown_field_set._clear()
1358    self._unknown_field_set = None
1359
1360  self._oneofs = {}
1361  self._Modified()

1423  def Modified(self):
1424    """Sets the _cached_byte_size_dirty bit to true,
1425    and propagates this to our listener iff this was a state change.
1426    """
1427
1428    # Note:  Some callers check _cached_byte_size_dirty before calling
1429    #   _Modified() as an extra optimization.  So, if this method is ever
1430    #   changed such that it does stuff even when _cached_byte_size_dirty is
1431    #   already true, the callers need to be updated.
1432    if not self._cached_byte_size_dirty:
1433      self._cached_byte_size_dirty = True
1434      self._listener_for_children.dirty = True
1435      self._is_present_in_parent = True
1436      self._listener.Modified()

1188  def IsInitialized(self, errors=None):
1189    """Checks if all required fields of a message are set.
1190
1191    Args:
1192      errors:  A list which, if provided, will be populated with the field
1193               paths of all missing required fields.
1194
1195    Returns:
1196      True iff the specified message has all required fields set.
1197    """
1198
1199    # Performance is critical so we avoid HasField() and ListFields().
1200
1201    for field in required_fields:
1202      if (field not in self._fields or
1203          (field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE and
1204           not self._fields[field]._is_present_in_parent)):
1205        if errors is not None:
1206          errors.extend(self.FindInitializationErrors())
1207        return False
1208
1209    for field, value in list(self._fields.items()):  # dict can change size!
1210      if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
1211        if field.label == _FieldDescriptor.LABEL_REPEATED:
1212          if (field.message_type.has_options and
1213              field.message_type.GetOptions().map_entry):
1214            continue
1215          for element in value:
1216            if not element.IsInitialized():
1217              if errors is not None:
1218                errors.extend(self.FindInitializationErrors())
1219              return False
1220        elif value._is_present_in_parent and not value.IsInitialized():
1221          if errors is not None:
1222            errors.extend(self.FindInitializationErrors())
1223          return False
1224
1225    return True

1103  def MergeFromString(self, serialized):
1104    serialized = memoryview(serialized)
1105    length = len(serialized)
1106    try:
1107      if self._InternalParse(serialized, 0, length) != length:
1108        # The only reason _InternalParse would return early is if it
1109        # encountered an end-group tag.
1110        raise message_mod.DecodeError('Unexpected end-group tag.')
1111    except (IndexError, TypeError):
1112      # Now ord(buf[p:p+1]) == ord('') gets TypeError.
1113      raise message_mod.DecodeError('Truncated message.')
1114    except struct.error as e:
1115      raise message_mod.DecodeError(e)
1116    return length   # Return this for legacy reasons.

1059  def SerializeToString(self, **kwargs):
1060    # Check if the message has all of its required fields set.
1061    if not self.IsInitialized():
1062      raise message_mod.EncodeError(
1063          'Message %s is missing required fields: %s' % (
1064          self.DESCRIPTOR.full_name, ','.join(self.FindInitializationErrors())))
1065    return self.SerializePartialToString(**kwargs)

1072  def SerializePartialToString(self, **kwargs):
1073    out = BytesIO()
1074    self._InternalSerialize(out.write, **kwargs)
1075    return out.getvalue()

806  def ListFields(self):
807    all_fields = [item for item in self._fields.items() if _IsPresent(item)]
808    all_fields.sort(key = lambda item: item[0].number)
809    return all_fields

830  def HasField(self, field_name):
831    try:
832      field = hassable_fields[field_name]
833    except KeyError as exc:
834      raise ValueError('Protocol message %s has no non-repeated field "%s" '
835                       'nor has presence is not available for this field.' % (
836                           message_descriptor.full_name, field_name)) from exc
837
838    if isinstance(field, descriptor_mod.OneofDescriptor):
839      try:
840        return HasField(self, self._oneofs[field].name)
841      except KeyError:
842        return False
843    else:
844      if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
845        value = self._fields.get(field)
846        return value is not None and value._is_present_in_parent
847      else:
848        return field in self._fields

855  def ClearField(self, field_name):
856    try:
857      field = message_descriptor.fields_by_name[field_name]
858    except KeyError:
859      try:
860        field = message_descriptor.oneofs_by_name[field_name]
861        if field in self._oneofs:
862          field = self._oneofs[field]
863        else:
864          return
865      except KeyError:
866        raise ValueError('Protocol message %s has no "%s" field.' %
867                         (message_descriptor.name, field_name))
868
869    if field in self._fields:
870      # To match the C++ implementation, we need to invalidate iterators
871      # for map fields when ClearField() happens.
872      if hasattr(self._fields[field], 'InvalidateIterators'):
873        self._fields[field].InvalidateIterators()
874
875      # Note:  If the field is a sub-message, its listener will still point
876      #   at us.  That's fine, because the worst than can happen is that it
877      #   will call _Modified() and invalidate our byte size.  Big deal.
878      del self._fields[field]
879
880      if self._oneofs.get(field.containing_oneof, None) is field:
881        del self._oneofs[field.containing_oneof]
882
883    # Always call _Modified() -- even if nothing was changed, this is
884    # a mutating method, and thus calling it should cause the field to become
885    # present in the parent message.
886    self._Modified()

1334  def WhichOneof(self, oneof_name):
1335    """Returns the name of the currently set field inside a oneof, or None."""
1336    try:
1337      field = message_descriptor.oneofs_by_name[oneof_name]
1338    except KeyError:
1339      raise ValueError(
1340          'Protocol message has no oneof "%s" field.' % oneof_name)
1341
1342    nested_field = self._oneofs.get(field, None)
1343    if nested_field is not None and self.HasField(nested_field.name):
1344      return nested_field.name
1345    else:
1346      return None

1364def _UnknownFields(self):
1365  if self._unknown_field_set is None:  # pylint: disable=protected-access
1366    # pylint: disable=protected-access
1367    self._unknown_field_set = containers.UnknownFieldSet()
1368  return self._unknown_field_set    # pylint: disable=protected-access

1371def _DiscardUnknownFields(self):
1372  self._unknown_fields = []
1373  self._unknown_field_set = None      # pylint: disable=protected-access
1374  for field, value in self.ListFields():
1375    if field.cpp_type == _FieldDescriptor.CPPTYPE_MESSAGE:
1376      if _IsMapField(field):
1377        if _IsMessageMapField(field):
1378          for key in value:
1379            value[key].DiscardUnknownFields()
1380      elif field.label == _FieldDescriptor.LABEL_REPEATED:
1381        for sub_message in value:
1382          sub_message.DiscardUnknownFields()
1383      else:
1384        value.DiscardUnknownFields()